package com.oct.ywsc.core.config;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.listener.ContainerProperties;

//@Data
//@ConfigurationProperties(prefix = "spring.kafka.listener")
//@Configuration
public class KafkaLintenerConfig {


    /**
     *       # 监听器并发度
     *       concurrency: 3
     *       # 手动提交偏移量
     *       ack-mode: MANUAL_IMMEDIATE
     */
    private Integer concurrency;

    private ContainerProperties.AckMode ackMode;


}
